package Creating_Observables

import (
	"context"
	"fmt"
	"github.com/reactivex/rxgo/v2"
)

// 创建 发布对象为函数的 可观察集合
func Demo_Start() {
	observable := rxgo.Start([]rxgo.Supplier{
		func(ctx context.Context) rxgo.Item {
			return rxgo.Of(1)
		},
		func(ctx context.Context) rxgo.Item {
			return rxgo.Of(2)
		}})
	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅：", item.E)
		}
		fmt.Println("订阅：", item.V)
	}
}
